package com.topsun.framework;

import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.cloud.stream.function.StreamBridge;
import org.springframework.context.annotation.Configuration;

//@Configuration
public class KafkaMessageSender {

//    @Autowired
//    private StreamBridge streamBridge;
//
//    /**
//     * 消息发送到默认通道：通道对应主题
//     */
//    public boolean sendToDefaultChannel(KafkaStreamListener.User user){
//        return streamBridge.send("supplier-out-0", user);
//    }


}
